//package com.jijia.webbase.controller;
//
//
//import com.jijia.webbase.interception.websocket.WebSocketInterception;
//import com.jijia.webbase.utils.WebSocketUtil;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.web.bind.annotation.RestController;
//
//import javax.websocket.*;
//import javax.websocket.server.PathParam;
//import javax.websocket.server.ServerEndpoint;
//
//
//@Slf4j
//@RestController
//@ServerEndpoint(value = "/chat/{id}",configurator= WebSocketInterception.class)
//public class WebSocketController {
//
//    @OnOpen
//    public void onOpen(@PathParam("id") String id, Session session){
//        WebSocketUtil.sessions.put(id,session);
//        log.debug(id+"已经连接到服务器！");
//    }
//
//
//    //规定消息的 格式 是    duifangId:message
//    @OnMessage
//    public void onMessage(@PathParam("id") String id,String message,Session session){
//        log.debug("message={}",message);
//        String msg = message.substring(message.indexOf(":"));
//        Long duifangId = Long.valueOf(message.substring(0,message.indexOf("：")));
//        WebSocketUtil.sendMessage(WebSocketUtil.sessions.get(duifangId.toString()),msg);
//    }
//
//
//
//
//    @OnClose
//    public void onClose(@PathParam("id") String id,Session session){
//
//    }
//
//    @OnError
//    public void onError(@PathParam("id") String id,Session session,Throwable throwable){
//        log.error("id={}连接出错！",id);
//        throwable.printStackTrace();
//    }
//
//
//}
